package org.niit.controller

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.service.WeiTimeService

class WeiTimeController {

  private val weiTimeService = new WeiTimeService

  def dispatch(data: DStream[AdClickData]): Unit = {
    weiTimeService.dataAnalysis(data) //调用相应的Service模块
  }

}